package hanlen.mq.starter.core.impl;

import hanlen.mq.starter.bean.MessageWrap;
import hanlen.mq.starter.core.RedisQueueExportService;
import lombok.extern.slf4j.Slf4j;

/**
 * mq-spring-boot-starter
 *
 * @author MrYe
 * @Description
 * @date 2021-10-26 16:06
 */
@Slf4j
public class DefaultRedisQueueExportServiceImpl implements RedisQueueExportService {

    @Override
    public void alarm(String queueName, Integer messageSize) {
        log.info("hanlen-redis-queue:{} size:{}", queueName, messageSize);
    }

    @Override
    public void overflowPolicy(String queueName, MessageWrap message) {

    }

}
